package com.example.studymoudle.observer_design_pattern;

/**
 * 抽象观察者 接口
 * @param <T>
 */
public interface Observer<T> {

    //用于订阅成功的回调
    void onSubscribe();

    //update()  收到消息
    void onNext(T t);

    //出错的回调
    void onError(Throwable e);

    //从订阅到消息发送全部完成
    void onComplete();
}
